package top.hjcwzx.wrench.mqtt.strategy;

import java.util.List;
import java.util.Map;
import java.util.function.Consumer;

/**
 *
 * <p><b>类名：</b> MqttMessageHandler</p>
 * <p><b>描述：</b> 消息处理器</p>
 * <p><b>创建时间：</b> 2025-06-17 17:01</p>
 *
 * @author 胡锦程
 */
public interface MqttMessageHandler {
    /**
     * 处理消息
     * @param topic 主题
     * @param payload 消息
     * @param topicHandlerMap 处理器
     */
    void handleMessage(String topic, String payload, Map<String, List<Consumer<Object>>> topicHandlerMap);
}
